package com.aiwiown.snackmq.network.handler;

import com.aiwiown.snackmq.common.message.Message;
import com.aiwiown.snackmq.common.message.MessageType;

/**
 * 客户端侧消息处理器接口。
 * 用于处理 Broker 主动发送给客户端的请求，例如事务状态回查。
 */
public interface ClientMessageHandler {
    /**
     * 获取此处理器能处理的消息类型。
     * @return 消息类型
     */
    MessageType getMessageType();

    /**
     * 处理来自 Broker 的消息。
     * @param message Broker 发送的消息
     */
    void handle(Message message);
}